Instance 0

Class0.shutdown_waitingOver_abruptShutdown()#0{
    final List<Integer> pool = new ArrayList<Integer>();
    backgroundExecutor.submit(new SleepingRunnable(1, 1000, pool));
    backgroundExecutor.submit(new SleepingRunnable(2, 1000, pool));
    backgroundExecutor.submit(new SleepingRunnable(3, 1000, pool));
    backgroundExecutor.submit(new SleepingRunnable(4, 1000, pool));
    backgroundExecutor.submit(new SleepingRunnable(5, 5000, pool));
    ExecutorServices.shutdown(backgroundExecutor, 100, TimeUnit.MILLISECONDS);
}


Instance 1

Class340.testNewCachedThreadPoolWithThreadFactory()#0{
        executorService.submit(new NoopRunnable());
        executorService.submit(new NoopRunnable());
}


Instance 2

Class340.testNewCachedThreadPool()#1{
        executorService.submit(new NoopRunnable());
        executorService.submit(new NoopRunnable());
}


Instance 3

Class260.createKafkaMessageConsumer(ConsumerConnector consumerConn,String topic,String topicInHeader,CountDownLatch messagesLatch,Map<String,Integer> topicCountMap)#1{
        for (final KafkaStream<byte[], byte[]> stream : consumerMap.get(topic)) {
            executor.submit(new KakfaTopicConsumer(stream, messagesLatch));
        }
        for (final KafkaStream<byte[], byte[]> stream : consumerMap.get(topicInHeader)) {
            executor.submit(new KakfaTopicConsumer(stream, messagesLatch));
        }
}


Instance 4

Class400.if_two_threads_wait_concurrently_then_both_of_them_will_read_the_same_output()#0{
        Future<Boolean> t1 = executor.submit(new WaitForOutput("Runtime", process.subscribeToOutput()));
        Future<Boolean> t2 = executor.submit(new WaitForOutput("Runtime", process.subscribeToOutput()));
        process.start();
}


Instance 5

Class270.testSubmitNullCallable()#1{
            e.submit((Callable) null);
}


Instance 6

Class480.submit(ExecutorService execService,Callable<T> proc,int numTasks,String label)#1{
            execService.submit(proc) ;
}


Instance 7

Class140.testExecuteNullRunnable()#1{
            e.submit((Runnable) null);
}